package cn.dm;

import cn.dm.entity.TranslatorDataWapper;
import com.lmax.disruptor.WorkHandler;

/**
 * @author Alienware
 * <p>
 * 此处想定义一个高层类,先不实现WorkHandler#onEvent()方法
 * 故定义为抽象类,将来在具体的netty-client和netty-server中再实现
 */
public abstract class MessageConsumer implements WorkHandler<TranslatorDataWapper> {

    protected String consumerId;

    public MessageConsumer(String consumerId) {
        this.consumerId = consumerId;
    }

    public String getConsumerId() {
        return consumerId;
    }

    public void setConsumerId(String consumerId) {
        this.consumerId = consumerId;
    }
}
